package com.chenjt.netty.one_helloWorld.helloWorld;

import io.netty.channel.ChannelInitializer;
import io.netty.channel.ChannelPipeline;
import io.netty.channel.socket.SocketChannel;
import io.netty.handler.codec.http.HttpServerCodec;

/**
 * 注释：
 *
 * @author chenjt
 * @date 2024/8/8 9:39
 */
public class TestServerInitializer extends ChannelInitializer<SocketChannel> {

    //连接注册之后就会被创建，创建之后就会执行initChannel()
    @Override
    protected void initChannel(SocketChannel ch) throws Exception {
        ChannelPipeline pipeline = ch.pipeline();//管道
        //将处理器添加到最后,第一个参数是给处理器增加一个名字
        pipeline.addLast("httpServerCodec",new HttpServerCodec());//每次都要new一个对象，不要弄成单例的
        //添加自定义处理器
        pipeline.addLast("testHttpServerHandler",new TestHttpServerHandler());

    }
}
